package cn.chinawyny.boot.bootdemo.consumers;

import cn.hutool.json.JSONUtil;
import org.springframework.kafka.annotation.KafkaListener;

/**
 * 消费者
 * 使用@KafkaListener注解,可以指定:主题,分区,消费组
 */
//@Component
public class KafkaConsumer {

    @KafkaListener(topics = {"t.behavior.requestLog"})
    public void receive(String message){
        System.out.println("app_log--消费消息:\n" + JSONUtil.parse(message).toStringPretty());
    }
}
